#include"../../client/rpc_client.hpp"
//发布客户端

int main()
{
    //1.实例化客户端对象
    auto client = std::make_shared<RPC_project::client::SubscribePublishClient>("127.0.0.1" ,7070);
    //2.创建cool主题
    bool ret = client->creatTopic("cool");
    if(!ret)
    {
        ELOG("创建主题失败！ ");
    }
    //3.向cool主题发布10条消息
    for(int i =0 ;i<10 ;i++)
    {
        client->publish("cool" ,"hello world_" +std::to_string(i));
    }

    client->shutdown();
    return 0;
}